package com.sailing.lianxi.common;

import java.util.Map;

import org.apache.kafka.clients.producer.Partitioner;
import org.apache.kafka.common.Cluster;

/**
 * Partitioner类示例
 * @author Administrator
 *
 */
public class MyPartitioner implements Partitioner{

	public void configure(Map<String, ?> configs) {
	}

	public int partition(String topic, Object key, byte[] keyBytes,
			Object value, byte[] valueBytes, Cluster cluster) {
		return 0;
	}

	public void close() {
		
	}

}
